package com.qf.service.Impl;


import com.qf.service.PushSubmitToQueueService;
import com.qianfeng.smsplatform.common.constants.RabbitMqConsants;
import com.qianfeng.smsplatform.common.model.Standard_Submit;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;



/**
 * Created by jackiechan on 2020-02-26 15:56
 *
 * @Author jackiechan
 */

//这里这个功能没有测试 因为需要新建一个项目 而且难度也不大 这里就没有测试
//需要的话再测试一下吧 这样因为时间的关系 直接往下走
@Service
public class PushSubmitToQueueServiceImpl implements PushSubmitToQueueService {
    @Autowired
    private RabbitTemplate template;


    @Override
    public void sendSmsSubitToQueue(List<Standard_Submit> standard_submits) {
        for (Standard_Submit submit : standard_submits) {
//            submit.setSource(1);//source 代表的是通过 http 还是 web 的方式来发送的 1是 http
            template.convertAndSend(RabbitMqConsants.TOPIC_PRE_SEND,submit);

        }
    }
}
